from hdfs import collect


def entry():
    t = collect.Collect()
    t.start()
    return [t, ]


if __name__ == '__main__':
    threads = entry()
    for t in threads:
        t.join()
